import org.apache.spark.streaming.{Seconds, StreamingContext}
import org.apache.spark.{SparkConf, SparkContext}

object MAIN {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("Streaming").setMaster("yarn-client")
    val sc = new SparkContext(conf)
    val ssc = new StreamingContext(sc,Seconds(1))



    ssc.start()
    ssc.awaitTermination()
  }
}
